//package com.shuai.frame.server.tcp;
//
//
//import io.vertx.core.Handler;
//import io.vertx.core.Vertx;
//import io.vertx.core.buffer.Buffer;
//import io.vertx.core.net.NetServer;
//import io.vertx.core.parsetools.RecordParser;
//import lombok.extern.slf4j.Slf4j;
//
///**
// * 测试粘包和半包问题测试
// */
//@Slf4j
//public class VertTcpServiceTest {
//
//    public void doStart(int port) {
//        // 创建 Vert.x 实例
//        Vertx vertx = Vertx.vertx();
//
//        // 创建 TCP 服务器
//        NetServer server = vertx.createNetServer();
//
//        // 处理请求
////        server.connectHandler(new TcpServerHandler());
//        server.connectHandler(socket -> {
//            String testMessage = "Hello, server!Hello, server!Hello, server!Hello, server!";
//            int messageLength = testMessage.getBytes().length;
//            RecordParser recordParser = RecordParser.newFixed(messageLength);
//            recordParser.setOutput(buffer -> {
//                String x = new String(buffer.getBytes());
//                System.out.println(x);
//                if (x.length() == messageLength) {
//                    System.out.println("good");
//                } else if (x.length() < messageLength) {
//                    System.out.println("半包");
//                } else {
//                    System.out.println("粘包");
//                }
//            });
//            socket.handler(recordParser);
//        });
//
//        // 启动 TCP 服务器并监听指定端口
//        server.listen(port, result -> {
//            if (result.succeeded()) {
//                log.info("TCP server started on port " + port);
//            } else {
//                log.info("Failed to start TCP server: " + result.cause());
//            }
//        });
//    }
//
//    public static void main(String[] args) {
//        new VertTcpServiceTest().doStart(8888);
//    }
//}
